package com.xs.test;

import java.io.IOException;
import java.util.Random;

import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.xs.producer.Produce;

/**
 * @Title: <P>Test.java</P>
 * @Package <P>com.xs.test</P>
 * @Description: <P>TODO该类...</P>
 * @author renweiping
 * @date 2019年3月11日 下午1:01:49
 * @version 1.0
 */

public class ProduceTest3 {


	private static final Logger logger = LoggerFactory.getLogger(Produce.class);
	public static void main(String[] args) throws IOException, InterruptedException {
		for(;;){
			Thread.sleep(1000);
			logger.info(new Random().nextInt(10000)+"");
		}
	}

}
